package com.whuan.stream.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

public interface MqConfig {

    String SENDTOINPUT = "sendToInput";
    String SENDTOOUTPUT = "sendToOutput";

    @Input(MqConfig.SENDTOINPUT)
    SubscribableChannel input();

    @Output(MqConfig.SENDTOOUTPUT)
    MessageChannel output();


}
